package com.example.kafka.config;

import org.apache.kafka.clients.admin.NewTopic;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;

@Component
public class TopicInitialConfig {

	/**
	 * 这里创建topic操作，可以通过修改分区参数，来修改topic分区数，修改分区数不会导致数据消失，但是
	 * 分区数只能增加，不能减小，这里即使设置更小的分区数，也不会使得kafka实际分区数变小
	 * @return
	 */
	@Bean
	public NewTopic initTopic() {
		//参数为：topic名称，分区数，副本数
		return new NewTopic("topic.initial", 1, (short)1);
	}
}
